<?php
namespace backend\components;

/**
 * FTP操作类
 * @author chenzhouyu
 *
 * 使用$ftps = pc_base::load_sys_class('ftps');进行初始化。
 * 首先通过　$ftps->connect($host,$username,$password,$post,$pasv,$ssl,$timeout);进行FTP服务器连接。
 * 通过具体的函数进行FTP的操作。
 * $ftps->mkdir() 创建目录，可以创建多级目录以“/abc/def/higk”的形式进行多级目录的创建。
 * $ftps->put()上传文件
 * $ftps->rmdir()删除目录
 * $ftps->f_delete()删除文件
 * $ftps->nlist()列出指定目录的文件
 * $ftps->chdir()变更当前文件夹
 * $ftps->get_error()获取错误信息
 */
class ftp
{
	
    //FTP 连接资源
    private $link;
    //FTP 连接时间
    public $link_time;
    //错误代码
    private $err_code = 0;
    //传送模式{文本模式：FTP_ASCII，二进制模式：FTP_BINARY}
    public $mode = 2;

    /**
     * 连接FTP服务器
     * @param string $host         服务器地址
     * @param string $username     用户名
     * @param string $password     密码
     * @param integer $port        服务器端口，默认值为21
     * @param boolean $pasv        是否开启被动模式
     * @param boolean $ssl         是否使用SSL连接
     * @param integer $timeout     超时时间
     */
    public function connect($host, $username='', $password='', $port='21', $pasv=false, $ssl=false, $timeout=30)
    {
		//return true;
		$start = time();
		
        if($ssl)
        {
            if(!$this->link = @ftp_ssl_connect($host, $port, $timeout))
            {
                $this->err_code = 1;
                return false;
            }
        }
        else
        {
			
            if(!$this->link = @ftp_connect($host, $port, $timeout))
            {
                $this->err_code = 1;
                return false;
            }
        }

        if(@ftp_login($this->link, $username, $password))
        {
            if($pasv)
            {
                ftp_pasv($this->link, true);
            }
            $this->link_time = time()-$start;
            return true;
        }
        else
        {
            $this->err_code = 1;
            return false;
        }
    }
    /**
	 * 创建文件夹
	 * @param string $dirname 目录名，
	 */
	public function mkdir($dirname) {
		$path_arr = explode('/',$dirname);       // 取目录数组  
		foreach($path_arr as $key=>$val)
		{
			if(trim($val)=='')
				unset($path_arr[$key]);
		}
	
		$path_div = count($path_arr);        // 取层数 
		if (!$this->link) {
			$this->err_code = 2;
			return false;
		} 
		//echo '层数：'.$path_div.'<br>';
		$dirname = $this->ck_dirname($dirname);
		$nowdir = ftp_pwd($this->link).'/';//返回当前目录名
		//echo '创建目录数组';
		//print_r($dirname);
		//echo '<br>';
		foreach ($dirname as $v) {
			if ($v && !$this->chdir($nowdir.$v)) {
				
				if ($nowdir) $this->chdir($nowdir);
				@ftp_mkdir($this->link, $v);
			}
			if($v) $nowdir .= $v.'/';
		}
		//echo '当前目录:'.ftp_pwd($this->link).'/<br>';//返回当前目录名
		// 回退到根 
		//for($i=1;$i<=$path_div;$i++)  modified by 李滨
		for($i=1;$i<$path_div;$i++)         
		{ 
		  @ftp_cdup($this->link); 
		} 
		return true;
	}
	
	/**
	 * 上传文件
	 * @param string $remote 远程存放文件名
	 * @param string $local 本地存放地址
     * @param int $return 是否打印执行过程,默认执行，0不执行
	 */
    public function put($remote, $local,$return =1) {
        if (!$this->link) {
            $this->err_code = 2;
            return false;
        }
        $dirname = pathinfo($remote,PATHINFO_DIRNAME);
        $baseDir = ftp_pwd($this->link);
        if($return){
            echo '当前目录：'.$baseDir.'===<br />初始目录列表';
            print_r($this->nlist(''));
            echo '<br>开始进入目录为：'.$dirname.'<br>';
        }

        if (!$this->chdir($dirname)) {
            if($return) echo '目录不存在 开始创建-----<br>';
            $this->mkdir($dirname);
            $this->chdir($dirname);
            if($return){
                print_r($this->nlist(''));
                echo '进入目录;<br>';
            }

        }

        if (@ftp_put($this->link, pathinfo($remote,PATHINFO_BASENAME), $local, $this->mode)) {
            $this->chdir($baseDir);//进入初始文件夹
            return true;
        } else {
            $this->err_code = 7;
            $this->chdir($baseDir);//进入初始文件夹
            return false;
        }
    }
	
	/**
	 * 删除文件夹
	 * @param string $dirname  目录地址
	 * @param boolean $enforce 强制删除
	 */
	public function rmdir($dirname, $enforce = false) {
		if (!$this->link) {
			$this->err_code = 2;
			return false;
		} 
		$list = $this->nlist($dirname);
		if ($list && $enforce) {
			$this->chdir($dirname);
			foreach ($list as $v) {
				$this->f_delete($v);
			}
		} elseif ($list && !$enforce) {
			$this->err_code = 3;
			return false;
		}
		@ftp_rmdir($this->link, $dirname);
		return true;
	}
	
	/**
	 * 删除指定文件
	 * @param string $filename 文件名
	 */
	public function f_delete($filename) {
		if (!$this->link) {
			$this->err_code = 2;
			return false;
		} 
		if (@ftp_delete($this->link, $filename)) {
			return true;
		} else {
			$this->err_code = 4;
			return false;
		}
	}
	
	/**
	 * 返回给定目录的文件列表
	 * @param string $dirname  目录地址
	 * @return array 文件列表数据
	 */
	public function nlist($dirname) {
		if (!$this->link) {
			$this->err_code = 2;
			return false;
		} 
		if ($list = @ftp_nlist($this->link, $dirname)) {
			return $list;
		} else {
			$this->err_code = 5;
			return false;
		}
	}
	
	/**
	 * 在 FTP 服务器上改变当前目录
	 * @param string $dirname 修改服务器上当前目录
	 */
	public function chdir($dirname) {
		if (!$this->link) {
			$this->err_code = 2;
			return false;
		} 
		if (@ftp_chdir($this->link, $dirname)) {
			return true;
		} else {
			$this->err_code = 6;
			return false;
		}
	}
	
	/**
	 * 获取错误信息
	 */
	public function get_error() {
		if (!$this->err_code) return false;
		$err_msg = array(
			'1'=>'Server can not connect',
			'2'=>'Not connect to server',
			'3'=>'Can not delete non-empty folder',
			'4'=>'Can not delete file',
			'5'=>'Can not get file list',
			'6'=>'Can not change the current directory on the server',
			'7'=>'Can not upload files'
		);
		return $err_msg[$this->err_code];
	}
	
	/**
	 * 检测目录名
	 * @param string $url 目录
	 * @return 由 / 分开的返回数组
	 */
	private function ck_dirname($url) {
		$url = str_replace('\\', '/', $url);
		$urls = explode('/', $url);
		return $urls;
	}
	
	/**
	 * 关闭FTP连接
	 */
	public function close() {
		return @ftp_close($this->link);
	}


}


